from io import BytesIO
from minio import Minio, S3Error
from airflow import DAG
from airflow.operators.python import PythonOperator
from airflow.operators.bash import BashOperator
from airflow.providers.cncf.kubernetes.operators.spark_kubernetes import SparkKubernetesOperator
from datetime import datetime, timedelta
{% for dependency in python_dependencies %}
{{dependency}}
{% endfor %}